package me;

public class RecordProducer {
	
	private RecordBuffer buffer;
	
	public RecordProducer(RecordBuffer buffer) {
		this.buffer = buffer;
	}
	
	public void  send(Object record) {
		try {
			buffer.put(record);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}
